package com.ccc.mq.dynamic.service;

import com.ccc.mq.dynamic.pojo.RocketTopicMsgVO;

import java.util.List;

/**
 * 消费者服务接口
 */
public interface RoketConsumerService {

    List<RocketTopicMsgVO> list();

    void startConsumer(RocketTopicMsgVO vo);

    /**
     * 启动一个消费者
     * @param rocketTopicId 消费者信息记录id
     */
    void startConsumer(Long rocketTopicId);

    /**
     * 下线一个消费者
     * @param rocketTopicId 消费者信息记录id
     */
    void removeConsumer(Long rocketTopicId);

    /**
     * 重启消费者
     * @param rocketTopicId 消费者信息记录id
     */
    void restartConsumer(Long rocketTopicId);
}